package net.oschina.allchat.server.framework.pipe.stream;

import net.oschina.allchat.server.framework.core.annotations.Component;
import net.oschina.allchat.server.framework.core.connection.IConnectionContext;
import net.oschina.allchat.server.framework.core.integration.IMessage;
import net.oschina.allchat.server.framework.core.integration.IMessageProcessor;

@Component("default.routing.message.processor")
public class DefaultRoutingMessageProcessor implements IMessageProcessor {

	@Override
	public void process(IConnectionContext context, IMessage message) {
		context.write(message.getPayload());
	}

}
